package com.houger.ddd.common.config.kafka;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 此类的描述是：Kafka 配置信息
 *
 * @date 2019-01-15 20:50
 **/
@ConfigurationProperties(prefix = "spring.kafka")
@Data
public class KafkaProperties {
    /**
     * Broker 的服务地址
     */
    private List<String> bootstrapServers;

    /**
     * Broker 连接用户名
     */
    private String username;
    /**
     * Broker 连接密码
     */
    private String password;

    /**
     * 生产者的配置信息
     */
    private KafkaProducerProperties producer = new KafkaProducerProperties();

    /**
     * 消费者的配置信息
     */
    private KafkaConsumerProperties consumer = new KafkaConsumerProperties();

    /**
     * 消费者的配置信息 Map
     */
    private Map<String, KafkaConsumerProperties> consumerList = new HashMap<>();

}